// package com.zmn.oms.task.subscribe;
//
// import com.aliyun.drc.clusterclient.ClusterClient;
// import com.aliyun.drc.clusterclient.DefaultClusterClient;
// import com.aliyun.drc.clusterclient.RegionContext;
// import org.springframework.beans.factory.annotation.Autowired;
// import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
// import org.springframework.boot.context.properties.ConfigurationProperties;
// import org.springframework.context.annotation.Bean;
// import org.springframework.context.annotation.Configuration;
//
// /**
//  * 类描述：订单数据变化订阅
//  *
//  * @author lujia
//  * @date 2018/12/05 14:08
//  */
// @Configuration
// @ConfigurationProperties(prefix = "aliyun.dts")
// @ConditionalOnExpression("'${zmn.dts.type}'.equalsIgnoreCase('aliyun')")
// public class DtsSubscribeConfiguration {
//
//     private String accessKey;
//     private String accessSecret;
//     private String orderWorkInstanceID;
//     private boolean usePublicIp = true;
//
//     @Bean
//     public RegionContext regionContext(){
//         RegionContext context = new RegionContext();
//         context.setUsePublicIp(usePublicIp);
//         context.setAccessKey(accessKey);
//         context.setSecret(accessSecret);
//         return context;
//     }
//
//     @Bean(name = "orderChangeDtsClient", initMethod = "start")
//     public ClusterClient clusterClient(RegionContext regionContext, @Autowired DtsOrderClusterListener orderClusterListener)
//             throws Exception {
//         DefaultClusterClient client = new DefaultClusterClient(regionContext);
//         client.addConcurrentListener(orderClusterListener);
//         client.askForGUID(orderWorkInstanceID);
//         return client;
//     }
//
//
//     public String getAccessKey() {
//         return accessKey;
//     }
//
//     public void setAccessKey(String accessKey) {
//         this.accessKey = accessKey;
//     }
//
//     public String getAccessSecret() {
//         return accessSecret;
//     }
//
//     public void setAccessSecret(String accessSecret) {
//         this.accessSecret = accessSecret;
//     }
//
//     public String getOrderWorkInstanceID() {
//         return orderWorkInstanceID;
//     }
//
//     public void setOrderWorkInstanceID(String orderWorkInstanceID) {
//         this.orderWorkInstanceID = orderWorkInstanceID;
//     }
//
//     public boolean isUsePublicIp() {
//         return usePublicIp;
//     }
//
//     public void setUsePublicIp(boolean usePublicIp) {
//         this.usePublicIp = usePublicIp;
//     }
// }
